package com.pk.flink.functions.source;

import org.apache.flink.streaming.api.functions.co.CoFlatMapFunction;
import org.apache.flink.util.Collector;

public class MyCoFlatMapFunction implements CoFlatMapFunction<Integer, String, Object> {
    @Override
    public void flatMap1(Integer integer, Collector<Object> collector) throws Exception {
        collector.collect("PK_" + (integer * 10));
    }

    @Override
    public void flatMap2(String s, Collector<Object> collector) throws Exception {
        collector.collect("PK_" + s);
    }
}
